package com.hjy.springbootinit.mq;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.nio.charset.StandardCharsets;

/**
 * @version 1.0
 * @Author HJY_Maker
 * @Date 2024/5/21 星期二 10:28
 */

/**
 * 操作rabbitmq的客户端。
 */
public class SingleProducer {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        //创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
//        factory.setPort();
//        factory.setUsername();
        //建立连接、创建频道
        //程序通过频道来
        try (Connection connection = factory.newConnection();
            Channel channel = connection.createChannel()) {
                //创建消息队列
                channel.queueDeclare(QUEUE_NAME, false, false, false, null);
                String message = "Hello World!";
                channel.basicPublish("", QUEUE_NAME, null, message.getBytes(StandardCharsets.UTF_8));
                System.out.println(" [x] Sent '" + message + "'");
        }
    }
}
